package com.oct.ywsc.core.bean;


import lombok.extern.slf4j.Slf4j;

@Deprecated
@Slf4j
public class KafkaListenerJob
//        implements Runnable
{

//    private KafkaConsumerListener kafkaConsumerListener;
//
//    public KafkaListenerJob(KafkaConsumerListener kafkaConsumerListener){
//        this.kafkaConsumerListener = kafkaConsumerListener;
//    }
//
//
//    @Override
//    public void run() {
//        log.info("kafka 消息监听任务启动。");
//        while (true){
//            try {
//            }catch (Exception e){
//                log.error("监听Kafka消息异常：" , e);
//            }
//        }
//    }
}
